package com.project.service;

import reactor.core.publisher.Flux;

/**
 * @Author: zhoujinchuan
 * @Description: （）
 * @Date: 2025/2/24 14:47
 */
public interface FluxSteamAssistant {

    /**
     * 使用 Flux 进行流式处理
     * @param message
     * @return
     */
    Flux<String> chat(String message);

}
